package com.ojoin.ojoin.eb_spider.service;

import java.util.concurrent.BlockingQueue;

/**
 * Created by liaowuhen on 2017/3/22.
 */
public interface QueueService<T> {
    T consume() throws InterruptedException;

    void produce(T msg) throws InterruptedException;

    boolean isEmpt() throws InterruptedException;

    BlockingQueue<T> getQueue();

}
